package com.example.ailiyuncloud.service;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.lang.NonNull;

import java.util.List;

/**
 * @Author: lqj
 * @Date: 2024/04/08/21:56
 * @Description:
 */
public interface KafkaService {

    Object kafkaProducer(@NonNull String topic, @NonNull String info);

    Object kafkaConsumer(ConsumerRecord<?, ?> record,Acknowledgment ack);
}
